package com.wxy.config;

import com.alibaba.druid.pool.DruidDataSource;

import java.sql.Connection;
import java.sql.SQLException;

/**
 * @author 47868
 */
public class GetConnectionConfig {
    public static Connection getConnection(com.wxy.eneity.Connection connection) {
        try {
            DruidDataSource ds = new DruidDataSource();
            ds.setDriverClassName("com.mysql.cj.jdbc.Driver");
            ds.setUsername(connection.getUsername());
            ds.setPassword(connection.getPassword());
            ds.setUrl(connection.getUrl());
            ds.setMaxActive(10);
            ds.setMaxWait(2000);
            // 关键：控制重连行为
            // 获取连接失败后中断，不再重试
            ds.setBreakAfterAcquireFailure(true);
            // 连接错误重试次数（0表示不重试）
            ds.setConnectionErrorRetryAttempts(0);
            return ds.getConnection();
        }
        catch (SQLException e) {
            throw new RuntimeException(e);
        }
    }
}
